#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2017/5/16 10:51
# @Author  : Leixu
# @Site    : 
# @File    : celery_test.py
# @Software: PyCharm Community Edition
from __future__ import absolute_import

from celery import Celery


app = Celery('task',
             broker='amqp://a1:a1@192.168.2.24/spider1',
             backend='redis://:bigdata@192.168.2.24:6379/2',
             include=['luobo.component.celery_c.task'])

app.config_from_object('luobo.component.celery_c.config')

if __name__ == '__main__':
    app.start()
